package com.smile.window;

public class TimeWindow {

    //滚动窗口
//    DataStream<Tuple2<String, Double>> minTempPerWindowStream = dataStream
//            .map(new MapFunction<SensorReading, Tuple2<String, Double>>() {
//                @Override
//                public Tuple2<String, Double> map(SensorReading value) throws
//                        Exception {
//                    return new Tuple2<>(value.getId(), value.getTemperature());
//                }
//            })
//            .keyBy(data -> data.f0)
//            .timeWindow( Time.seconds(15) )
//            .minBy(1);
  //滑动窗口
//    DataStream<SensorReading> minTempPerWindowStream = dataStream
//            .keyBy(SensorReading::getId)
//            .timeWindow( Time.seconds(15), Time.seconds(5) )
//            .minBy("temperature");

}
